package com.example.hosrxjavaapplication.observable;

public interface Observable<T> {

    //指定事件发送线程
    Observable observeOn(Schedulers schedulers);

    //设置事件产生线程
    Observable subscribeOn(Schedulers schedulers);

    //订阅指定的工作线程 在方法内实现操作
    Observable work(Work work);

    //设置事件发送间隔时长 单位毫秒
    Observable interval(int interval);

    //订阅事件监听器
    void subscribe(Observer<T> observer);
}
